package org.jetlinks.mqtt.client;

import io.netty.buffer.ByteBuf;

import java.nio.charset.StandardCharsets;

public class MqttHandlerImpl implements MqttHandler {
    @Override // org.jetlinks.mqtt.client.MqttHandler
    public void onMessage(String topic, ByteBuf payload) {
        System.out.println(topic + "=>" + payload.toString(StandardCharsets.UTF_8));
    }

}
